package com.hxzy.rabbitmqconsumer.rabbitmq.consumer;

import com.hxzy.common.QueueConst;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @Author wy
 * @Description 消费者（消费queue02）
 * @Date 2024/2/21 14:53
 * @Version 1.0
 */
@Component
public class Queue02Consumer {

    /**
     * 创建线程1
     * @param msg
     */
    @RabbitListener(queues = {QueueConst.QUEUE02})
    @RabbitHandler
    public void consumer(String msg){
        System.out.println("----收到queue02的消息："+msg);
        int i=1/0;
        //记录错误到redis/数据库表中
        //做什么业务逻辑，你自己根据需求来做了
    }


}
